#!/bin/bash

arr=(CUSTOMER_MASTER ACCOUNT_MASTER TRANSACTION_DETAIL UBO_INFO WATCHLIST_MASTER WATCHLIST_DETAIL SCREENING_RESULT ALERT SUSPICIOUS_TXN_REPORT MONITORING_RULE)

for i in "${arr[@]}"
do
    sqoop import \
		# 连接到Oracle数据库，指定连主机地址、端口、SID
		--connect jdbc:oracle:thin:@192.168.4.126:1521:orcl \
        # 数据库连接的用户名
        --username fxq \
        # 数据库连接的密码
        --password 123456 \
        # 要从Oracle数据库导入的表名
        --table "AML_$i" \
        # 指定HCatalog数据库
        --hcatalog-database ods \
        # 指定HCatalog表名
        --hcatalog-table "ODS_$i" \
        # 指定Hive表的分区键
        --hive-partition-key etl_date \
        # 指定Hive表分区键的值
        --hive-partition-value "2025-10-15" \
        # 设置MapReduce任务的Mapper数量为1，确保数据导入在一个Mapper中完成
	-m 1
done